package com.ruoyi.order.mqtt;

//import com.ruoyi.common.mqtt.RabbitMQConfig;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.rabbit.annotation.RabbitHandler;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.stereotype.Component;
//
//import java.text.SimpleDateFormat;
//import java.util.Date;

//@Slf4j
//@Component
public class ImmediateReceiver {

//    @RabbitListener(queues = RabbitMQConfig.IMMEDIATE_QUEUE)
//    @RabbitHandler
//    public void get(String msg) {
//        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//        log.info("收到延时消息时间：" + sdf.format(new Date()) + " Delay sent.");
//        log.info("收到延时消息了:" + msg);
//    }
}
